package com.it.app;

import com.it.constants.Constants;
import com.it.dao.HBaseDao;
import com.it.utils.HBaseUtils;

import java.io.IOException;

/**
 * @author : code1997
 * @date :2021-02-2021/2/7 10:59
 */
public class WeiBo {
    public static void init() {
        try {
            HBaseUtils.createNameSpace(Constants.NAMESPACE);
            HBaseUtils.createTable(Constants.TABLE_CONTENT,
                    Constants.TABLE_CONTENT_VERSION,
                    Constants.TABLE_CONTENT_CF);
            HBaseUtils.createTable(Constants.TABLE_RELATIONS,
                    Constants.TABLE_RELATIONS_VERSION,
                    Constants.TABLE_RELATIONS_CF1,
                    Constants.TABLE_RELATIONS_CF2);
            HBaseUtils.createTable(Constants.TABLE_INBOX,
                    Constants.TABLE_INBOX_VERSION,
                    Constants.TABLE_INBOX_CF);

        } catch (IOException e) {
            e.printStackTrace();
        }

    }

    /**
     * 初始化
     * 1001发布微博
     * 1002关注1001和1003
     * 获取1002初始化页面
     * 1003发布3条微博，同时1001发布两条微博
     * 获取1002初始化页面
     * 1002取关1003
     * 获取1002初始化页面
     * 1002再次关注1003
     * 获取1002初始化页面
     * 获取1001微博详情
     */
    public static void main(String[] args) {
        //init();
        /*HBaseDao.publishWeiBo("1001", "赶紧下课吧");
        HBaseDao.addAttends("1002", "1001","1003");
        HBaseDao.getInit("1002");*/
        /*HBaseDao.publishWeiBo("1003", "倒计时3");
        HBaseDao.publishWeiBo("1003", "倒计时2");
        HBaseDao.publishWeiBo("1003", "倒计时1");
        HBaseDao.publishWeiBo("1001", "火箭发射2");
        HBaseDao.publishWeiBo("1001", "火箭发射1");
        HBaseDao.getInit("1002");*/
        /*HBaseDao.delAttends("1002", "1003");
        HBaseDao.getInit("1002");*/
        /*HBaseDao.addAttends("1002", "1003");
        HBaseDao.getInit("1002");*/
        /*HBaseDao.getWeiBo("1001");*/
    }
}
